d609df075ed372fb0d9c4b123c42aef28515506c,joker-engine/src/main/java/cs/bilkent/joker/engine/region/impl/PipelineTransformerImpl.java,PipelineTransformerImpl,duplicateMergedPipeline,#number#number#OperatorReplica[]#number#PipelineReplicaId#PipelineReplica#boolean#,227

Before Change


        {
            final OperatorReplica operator = pipelineReplica.getOperator( i );
            final Supplier<TuplesImpl> outputSupplier = ( ( i == ( j - 1 ) ) && isLastMergedPipeline )
                                                        ? new NonCachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() )
                                                        : new CachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() );

            newOperatorReplicas[ operatorIndex++ ] = operator.duplicate( newPipelineReplicaId,
                                                                         operator.getQueue(),

After Change


        for ( int i = 1, j = pipelineReplica.getOperatorCount(); i < j; i++ )
        {
            final OperatorReplica operator = pipelineReplica.getOperator( i );
            final Supplier<TuplesImpl> outputSupplier = ( ( i == ( j - 1 ) ) && isLastMergedPipeline ) ? OutputSupplierUtils.newInstance(
                    lastOperatorOutputSupplierClass,
                    operator.getOperatorDef().inputPortCount() )
                                                                                                       : new CachedTuplesImplSupplier( operator.getOperatorDef().inputPortCount() );

            newOperatorReplicas[ operatorIndex++ ] = operator.duplicate( newPipelineReplicaId,
                                                                         operator.getQueue(),